google.golang.org/grpc.ClientConn.dopts (field)

84 uses

	google.golang.org/grpc (current package)
		call.go#L32: 	opts = combine(cc.dopts.callOptions, opts)
		call.go#L34: 	if cc.dopts.unaryInt != nil {
		call.go#L35: 		return cc.dopts.unaryInt(ctx, method, args, reply, cc, invoke, opts...)
		clientconn.go#L140: 		dopts:             defaultDialOptions(),
		clientconn.go#L150: 		opt.apply(&cc.dopts)
		clientconn.go#L154: 		opt.apply(&cc.dopts)
		clientconn.go#L166: 	pid := cc.dopts.channelzParentID
		clientconn.go#L172: 	if cc.dopts.channelzParentID != nil {
		clientconn.go#L181: 	if cc.dopts.copts.TransportCredentials == nil && cc.dopts.copts.CredsBundle == nil {
		clientconn.go#L184: 	if cc.dopts.copts.TransportCredentials != nil && cc.dopts.copts.CredsBundle != nil {
		clientconn.go#L187: 	if cc.dopts.copts.CredsBundle != nil && cc.dopts.copts.CredsBundle.TransportCredentials() == nil {
		clientconn.go#L190: 	transportCreds := cc.dopts.copts.TransportCredentials
		clientconn.go#L192: 		transportCreds = cc.dopts.copts.CredsBundle.TransportCredentials()
		clientconn.go#L195: 		for _, cd := range cc.dopts.copts.PerRPCCredentials {
		clientconn.go#L202: 	if cc.dopts.defaultServiceConfigRawJSON != nil {
		clientconn.go#L203: 		scpr := parseServiceConfig(*cc.dopts.defaultServiceConfigRawJSON)
		clientconn.go#L207: 		cc.dopts.defaultServiceConfig, _ = scpr.Config.(*ServiceConfig)
		clientconn.go#L209: 	cc.mkp = cc.dopts.copts.KeepaliveParams
		clientconn.go#L211: 	if cc.dopts.copts.UserAgent != "" {
		clientconn.go#L212: 		cc.dopts.copts.UserAgent += " " + grpcUA
		clientconn.go#L214: 		cc.dopts.copts.UserAgent = grpcUA
		clientconn.go#L217: 	if cc.dopts.timeout > 0 {
		clientconn.go#L219: 		ctx, cancel = context.WithTimeout(ctx, cc.dopts.timeout)
		clientconn.go#L228: 			case err == nil || !cc.dopts.returnLastError:
		clientconn.go#L238: 	if cc.dopts.scChan != nil {
		clientconn.go#L241: 		case sc, ok := <-cc.dopts.scChan:
		clientconn.go#L250: 	if cc.dopts.bs == nil {
		clientconn.go#L251: 		cc.dopts.bs = backoff.DefaultExponential
		clientconn.go#L259: 	cc.authority, err = determineAuthority(cc.parsedTarget.Endpoint(), cc.target, cc.dopts)
		clientconn.go#L265: 	if cc.dopts.scChan != nil && !scSet {
		clientconn.go#L268: 		case sc, ok := <-cc.dopts.scChan:
		clientconn.go#L277: 	if cc.dopts.scChan != nil {
		clientconn.go#L282: 	if creds := cc.dopts.copts.TransportCredentials; creds != nil {
		clientconn.go#L287: 		CredsBundle:      cc.dopts.copts.CredsBundle,
		clientconn.go#L288: 		Dialer:           cc.dopts.copts.Dialer,
		clientconn.go#L290: 		CustomUserAgent:  cc.dopts.copts.UserAgent,
		clientconn.go#L305: 	if cc.dopts.block {
		clientconn.go#L311: 			} else if cc.dopts.copts.FailOnNonTempDialError && s == connectivity.TransientFailure {
		clientconn.go#L323: 				if err = cc.connectionError(); err != nil && cc.dopts.returnLastError {
		clientconn.go#L336: 	interceptors := cc.dopts.chainUnaryInts
		clientconn.go#L339: 	if cc.dopts.unaryInt != nil {
		clientconn.go#L340: 		interceptors = append([]UnaryClientInterceptor{cc.dopts.unaryInt}, interceptors...)
		clientconn.go#L352: 	cc.dopts.unaryInt = chainedInt
		clientconn.go#L367: 	interceptors := cc.dopts.chainStreamInts
		clientconn.go#L370: 	if cc.dopts.streamInt != nil {
		clientconn.go#L371: 		interceptors = append([]StreamClientInterceptor{cc.dopts.streamInt}, interceptors...)
		clientconn.go#L383: 	cc.dopts.streamInt = chainedInt
		clientconn.go#L475: 	dopts           dialOptions          // Default and user specified dial options.
		clientconn.go#L548: 		case sc, ok := <-cc.dopts.scChan:
		clientconn.go#L598: 	if cc.dopts.defaultServiceConfig != nil {
		clientconn.go#L599: 		cc.applyServiceConfigAndBalancer(cc.dopts.defaultServiceConfig, &defaultConfigSelector{cc.dopts.defaultServiceConfig}, addrs)
		clientconn.go#L630: 	if cc.dopts.disableServiceConfig {
		clientconn.go#L708: 		dopts:        cc.dopts,
		clientconn.go#L890: 	if cc.dopts.authority != "" {
		clientconn.go#L891: 		return cc.dopts.authority
		clientconn.go#L1055: 	if cc.dopts.channelzParentID != nil {
		clientconn.go#L1332: 	if ac.cc.dopts.disableHealthCheck {
		clientconn.go#L1342: 	healthCheckFunc := ac.cc.dopts.healthCheckFunc
		clientconn.go#L1374: 		err := ac.cc.dopts.healthCheckFunc(ctx, newStream, setConnectivityState, healthCheckConfig.ServiceName)
		clientconn.go#L1531: 	for _, rb := range cc.dopts.resolvers {
		resolver_conn_wrapper.go#L55: 	if creds := cc.dopts.copts.TransportCredentials; creds != nil {
		resolver_conn_wrapper.go#L59: 		DisableServiceConfig: cc.dopts.disableServiceConfig,
		resolver_conn_wrapper.go#L61: 		CredsBundle:          cc.dopts.copts.CredsBundle,
		resolver_conn_wrapper.go#L62: 		Dialer:               cc.dopts.copts.Dialer,
		resolver_conn_wrapper.go#L139: 	if ccr.cc.dopts.disableServiceConfig {
		stream.go#L157: 	opts = combine(cc.dopts.callOptions, opts)
		stream.go#L159: 	if cc.dopts.streamInt != nil {
		stream.go#L160: 		return cc.dopts.streamInt(ctx, desc, cc, method, newClientStream, opts...)
		stream.go#L286: 	} else if cc.dopts.cp != nil {
		stream.go#L287: 		callHdr.SendCompress = cc.dopts.cp.Type()
		stream.go#L288: 		cp = cc.dopts.cp
		stream.go#L309: 	if !cc.dopts.disableRetry {
		stream.go#L315: 	if cc.dopts.binaryLogger != nil {
		stream.go#L316: 		if ml := cc.dopts.binaryLogger.GetMethodLogger(method); ml != nil {
		stream.go#L389: 	shs := cs.cc.dopts.copts.StatsHandlers
		stream.go#L431: 		dc:            cs.cc.dopts.dc,
		stream.go#L615: 	if cs.cc.dopts.disableRetry {
		stream.go#L1223: 	} else if ac.cc.dopts.cp != nil {
		stream.go#L1224: 		callHdr.SendCompress = ac.cc.dopts.cp.Type()
		stream.go#L1225: 		cp = ac.cc.dopts.cp